package com.cyzy.config;

import com.cyzy.sender.ChatProducer;
import org.apache.rocketmq.client.exception.MQClientException;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RocketMQConfig {
    @Bean
    public ChatProducer chatProducer() throws MQClientException {
        ChatProducer producer = new ChatProducer();
        return producer;
    }
}
